package com.woniuxy.consumer.listener;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * @author yellow Doctor
 * @date 2025-03-26
 * @desc 蜗牛创想：www.woniuxy.com
 */
@Component
public class ConsumerListener3 {

    /**
     * fanout应用场景:
     *   1、下单成功 支付完成
     *         通过消息 通过其他的 系统
     *             1、积分系统    收到消息 ===> 添加积分
     *             2、库存系统    收到消息 ===>  扣库存
     *             3、物流系统    收到消息 ===>  生成物流信息
     * direct应用场景:
     *   1、下单成功 支付完成
     *         通过消息 通过其他的 系统 （可以定向发送）
     *             1、积分系统    收到消息 ===> 添加积分
     *             2、库存系统    收到消息 ===>  扣库存
     *             3、物流系统    收到消息 ===>  生成物流信息
     */
//    /**
//     * msg.queue队列，
//     * 对指定的队列进行监听，并且将数据注入给方法的形参
//     */
    @RabbitListener(queues = "sz.queue")
    public void sendEmail(String msg) {
        System.out.println("我是消费者C1 消费深圳队列中的数据 =====>" + msg);
    }
//
//    @RabbitListener(queues = "gz.queue")
//    public void getObj(String msg) {
//        System.out.println("我是消费者C2 消费深广州列中的数据:" + msg);
//    }

}
